package com.rrd.cannl.sink;

import java.util.List;

import com.alibaba.otter.canal.protocol.CanalEntry.Column;

public class AbstractSink {

	 public  void printColumn(List<Column> columns) {
	        for (Column column : columns) {
	            System.out.println(column.getName() + " : " + column.getValue() + "    update=" + column.getUpdated());
	        }
	    }
	 
	 public void write(String val){
		 System.out.println(val);
	 }
	 public void write(String key,String val){
		 System.out.println(val);
	 }
}
